package com.example.source;

import org.apache.flink.connector.kafka.source.KafkaSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

/**
 * Created with IntelliJ IDEA.
 * ClassName: KafkaSourceDemo
 * Package: com.example.source
 * Description:
 * User: fzykd
 *
 * @Author: LQH
 * Date: 2023-07-18
 * Time: 14:16
 */

public class KafkaSourceDemo {
    public static void main(String[] args) {
    }
}
